package com.atbeijing.bigdata.spark.sql

import org.apache.spark.SparkConf
import org.apache.spark.sql.{DataFrame, SparkSession}

object SparkSQL02_SQL {

    def main(args: Array[String]): Unit = {

        // TODO 创建环境对象
        val sparkConf = new SparkConf().setMaster("local[*]").setAppName("SparkSQL")
        val spark: SparkSession = SparkSession.builder().config(sparkConf).getOrCreate()

        // JSON文件要求文件整体格式符合JSON要求
        // SparkSQL底层是SparkCore，SparkCore读取文件使用的是Hadoop
        // 所以要求是一行数据为JSON格式即可
        val df: DataFrame = spark.read.json("data/user.json")

        // 将DataFrame转换为一张临时视图
        df.createOrReplaceTempView("user")

        // 使用SQL的方式访问视图
        spark.sql("select age from user").show


        spark.stop()
    }
}
